6285e61435a69f885747c2f122a37a8012526d86,org.springframework.testsuite/src/test/java/org/springframework/jca/cci/CciTemplateTests.java,CciTemplateTests,testTemplateExecuteWithCreatorAndRecordFactoryNotSupported,#,142
Before Change
public void testTemplateExecuteWithCreatorAndRecordFactoryNotSupported() throws ResourceException {
MockControl connectionFactoryControl = MockControl.createStrictControl(ConnectionFactory.class);
ConnectionFactory connectionFactory = (ConnectionFactory) connectionFactoryControl.getMock();
MockControl connectionControl = MockControl.createStrictControl(Connection.class);
Connection connection = (Connection) connectionControl.getMock();
MockControl interactionControl = MockControl.createStrictControl(Interaction.class);
Interaction interaction = (Interaction) interactionControl.getMock();
MockControl inputRecordControl = MockControl.createStrictControl(Record.class);
Record inputRecord = (Record) inputRecordControl.getMock();
MockControl outputRecordControl = MockControl.createStrictControl(Record.class);
final Record outputRecord = (Record) outputRecordControl.getMock();
MockControl interactionSpecControl = MockControl.createStrictControl(InteractionSpec.class);
InteractionSpec interactionSpec = (InteractionSpec) interactionSpecControl.getMock();
connectionFactory.getConnection();
connectionFactoryControl.setReturnValue(connection);
connectionFactory.getRecordFactory();
connectionFactoryControl.setThrowable(new NotSupportedException("not supported"), 1);
connection.createInteraction();
connectionControl.setReturnValue(interaction);
interaction.execute(interactionSpec, inputRecord, outputRecord);
interactionControl.setReturnValue(true, 1);
interaction.close();
interactionControl.setVoidCallable(1);
connection.close();
connectionControl.setVoidCallable(1);
connectionFactoryControl.replay();
connectionControl.replay();
interactionControl.replay();
CciTemplate ct = new CciTemplate(connectionFactory);
ct.setOutputRecordCreator(new RecordCreator() {
public Record createRecord(RecordFactory recordFactory) {
assertTrue(recordFactory instanceof NotSupportedRecordFactory);
return outputRecord;
}
});
ct.execute(interactionSpec, inputRecord);
connectionFactoryControl.verify();
connectionControl.verify();
interactionControl.verify();
}
After Change
expect(connectionFactory.getConnection()).andReturn(connection);
expect(connectionFactory.getRecordFactory()).andThrow(new NotSupportedException("not supported"));
expect(connection.createInteraction()).andReturn(interaction);